package com.gandong8.trace.tool.consumer.rocketmq.custom;

import com.gandong8.trace.tool.consumer.TwoObject;
import com.gandong8.trace.tool.consumer.rocketmq.AbstractRocketMqListener;
import lombok.extern.slf4j.Slf4j;

@Slf4j
public class TopicTwoListener extends AbstractRocketMqListener<TwoObject> {
    @Override
    protected void execute(TwoObject message) {
        System.out.println("topic2：" + message);
    }

}
